package com.sxj.web.servlet;

import com.sxj.web.util.StringUtil;

import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.io.PrintWriter;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.util.Arrays;

/**
 * @author 石小俊
 * @date 2024年02月28日 18:56
 * 实现添加功能
 */
@WebServlet("/addEmp")
public class AddEmpServlet extends HttpServlet {
    @Override
    protected void service(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        response.setContentType("text/html;charset=utf-8");
        PrintWriter out = response.getWriter();
        // 获取表单中的数据
        // 此时所有请求的数据都被封装在请求对象中
        // 根据请求对象获取表单中的数据
        // 该方法获取的值是服务器值,对应的value属性值
        // String value = request.getParameter("key");
        // 从请求中获取数据的时候可能会存在乱码问题
        // 如果是Post请求,可以直接指定请求字符集
        request.setCharacterEncoding("utf-8");
        String name = request.getParameter("name");
        // 如果是get请求,是由服务器自动指定的,服务器默认字符集根据版本不同字符集不同
        // 此处使用的是tomcat7,默认字符集为ISO-8859-1
        // name = new String(name.getBytes("ISO-8859-1"),"UTF-8");
        // 也可以修改tomcat默认字符集
        String salary = request.getParameter("salary");
        String gender = request.getParameter("gender");
        String edu = request.getParameter("edu");
        String[] hobbies = request.getParameterValues("hobbies");
        System.out.println("name:" + name + ",salary:" + salary + ",gender:" + gender + ",edu:" + edu + ",hobbies:" + Arrays.toString(hobbies));

        Connection conn = null;
        PreparedStatement ps = null;
        String url = "jdbc:mysql://127.0.0.1:3306/ems?useUnicode=true&characterEncoding=utf-8";
        try {
            // JDBC操作
            Class.forName("com.mysql.jdbc.Driver");
            conn = DriverManager.getConnection(url,"root","");
            String sql = new StringBuffer()
                    .append("insert into ")
                    .append(" t_emp ")
                    .append("   (name,salary,gender,edu,hobbies)")
                    .append(" values ")
                    .append("   (?,?,?,?,?)")
                    .toString();
            ps = conn.prepareStatement(sql);
            ps.setString(1,name);
            ps.setDouble(2,Double.parseDouble(salary));
            ps.setString(3,gender);
            ps.setString(4,edu);
            ps.setString(5, StringUtil.arrayToString(hobbies));
            // 执行sql
            ps.executeUpdate();
//            out.print("<h1 style='color:green;'>恭喜您,添加成功</h1>");

            // 在Servlet中页面跳转有两种方式
            // 方式一:重定向,向服务器重新发送一次新的请求
            // 默认地址为    协议名://域名:端口
            // 而访问一个Servlet的完整地址为   协议名://域名:端口/应用名/访问命令
            // 此时跳转时必须指定应用名,应用名不可以写死,否则后期应用名发生改变之后会导致项目崩溃
//            response.sendRedirect("/web/findAll");
            // 可以通过请求对象获取到当前应用名
            String contextPath = request.getContextPath();
            System.out.println("contextPath:"+contextPath);
            response.sendRedirect(contextPath+"/findAll");
            // 重定向可以跨域
//            response.sendRedirect("https://www.baidu.com/");

            // 方拾二:转发,服务器内部控制权的转移,没有产生新的请求
            // 由于是服务器内部控制权的转移,因此不能跨应用
            // 默认地址中包含了应用名
            // 转发后地址栏没有发生改变,此时刷新页面的话会再次执行添加操作
            // 因此,此处不建议使用转发
//            request.getRequestDispatcher("/findAll").forward(request,response);
//            request.getRequestDispatcher("https://www.baidu.com/").forward(request,response);

            // 什么时候使用转发?什么时候使用重定向?

        } catch (Exception e) {
            e.printStackTrace();
            out.print("<h1 style='color:red;'>对不起,添加失败,错误原因:"+e.getMessage()+"</h1>");
        }
    }
}
